<?php
	
/**
 * 参数 filename 上传的文件名 
 * 
 * 参数 type 当 为 add 的时候 会将 表格 的 body  部分 同步进去 如果 是 其他 则 只 同步 标题
 * 
 * 参数 title 说明 填写的标题  没有的话  填写 者 不能看到 信息
 * 
 * 
 * 
 * */
	
	
//启动 回话功能
session_start();
header('Content-Type:application/json; charset=utf8');
//导入 配置信息
include("config.php");
//导入 上传功能的 类
include("procFileTypeClass.php");
//全局变量
//$status=false;//上传成功标注
$fileProc = new FileProc();//文件处理 类
$uploadDataMsg=new UploadDataType();//上传数据类
$reqData=new ReqDataType();//回执 信息类
$dbconf=new DBConfig();//数据库 连接 类

/****************
 * 
 * 文件处理开始
 * 
 * */

//测试--------------开始
//$status=true;
//$uploadDataMsg->filename="1234.xls";
////$uploadDataMsg->tableid="userid_1_table_0";
//$uploadDataMsg->userid=1;
//测试--------------结束

//上传文件成功 则获取 第一行数据  给数据库并处理 
//echo $_SESSION['userid'];
if(@$_GET['filename']&&@$_SESSION['userid']){
	$titlename="";
	$typename="";
	if(@$_GET['title']){
		$titlename=",title='".$_GET['title']."' ";
	}
	
	if(@$_GET['do']=='add'){
		$typename=",type='add' ";
	}else{
		$typename=",type='NOT' ";
	}
	$uploadDataMsg->filename=$_GET['filename'];
//	echo $_GET['filename'];
	//启动数据库 
	$conn= new mysqli($dbconf->servername,$dbconf->username,$dbconf->password,$dbconf->dbname);
	if ($conn->connect_error) {
		   // die("mysql连接失败: " . $conn->connect_error);
		   $reqData->status='error';
		   $reqData->type='mysql';
		   echo json_encode($reqData);
	}
	//读取文件
	//配置 登陆的 用户信息
	
	@$uploadDataMsg->userid=$_SESSION['userid'];

	$fileProc->getFileMsg($uploadDataMsg->filename);
	//获取 表格的 头信息
	$headData=$fileProc->procHeader($fileProc->data);
//	print_r($headData);
	$reqData->msg='getData';
	$uploadDataMsg->rows=$headData;
	$uploadDataMsg->len=$fileProc->len;
//	$uploadDataMsg->tablename="test";
//	echo $uploadDataMsg->getJson();
	
	//插入语句
	$sql = $uploadDataMsg->getSqlinTablelist();
	//插入
//	echo $sql;
	if ($conn->query($sql) === TRUE) {
		//插入数据成功 则 返回
	    $reqData->status='success';
//	    echo "ok";
	    //查询根据 用户id 和文件名 查找  插入的信息 补全 
	     $sql="SELECT * FROM `tablelist` WHERE filename ='$uploadDataMsg->filename' and userid ='$uploadDataMsg->userid' ORDER BY `tablelist`.`listid` DESC;";
	    $result = $conn->query($sql);
		if($result->num_rows>0){
			//查询表格id
			$row =$result->fetch_assoc();
			$uploadDataMsg->tableid=$row['tableid'];
			$json=addslashes($uploadDataMsg->getJson());
//			print_r($uploadDataMsg);
			
//			echo $json;
			$sql="UPDATE `tablelist` SET `tablejson`='$json' ,`mask`=md5('$uploadDataMsg->tableid') ".$titlename." ".$typename." WHERE filename ='$uploadDataMsg->filename' and userid ='$uploadDataMsg->userid' and tableid='$uploadDataMsg->tableid';";
			if ($conn->query($sql) === TRUE) {
				$reqData->status='success';
				$reqData->tableJson=json_decode($uploadDataMsg->getJson());
			} else{
				$reqData->status='error';
			}
		}
	}else{
		
	}
	
	//创建 语句
	$sql=$fileProc->getSqlCreate($uploadDataMsg);
	if ($conn->query($sql) === TRUE) {
	   $reqData->status='success';
	   $reqData->msg='creat success';
	} else {
	   $reqData->status='error';
	   $reqData->msg='creat error';
	}
		
	if(@$_GET["do"]=='add'){
		//插入 body
		$fileProc->packUploadDataJson($fileProc->data);
		$sql=$fileProc->getBodySqlValue($uploadDataMsg);
		
		if (mysqli_multi_query($conn, $sql)) {
		   $reqData->status='success';
		   $reqData->msg='add success';
		}else {
		   $reqData->status='error';
		   $reqData->msg='add error';
		}
			
		//	print_r();
		//	print_r($fileProc->data);
			$conn->close();
		}
	}
	
	echo json_encode($reqData);
/****************
 * 
 * 文件处理 结束
 * 
 * */
?>